package ex.datastream.functions.richFunction;

import org.apache.flink.api.java.tuple.Tuple;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.functions.windowing.ProcessWindowFunction;
import org.apache.flink.streaming.api.windowing.windows.TimeWindow;
import org.apache.flink.util.Collector;

public  class ProcessWindowFunc extends ProcessWindowFunction<Integer, Tuple2<Long, Integer>, Tuple, TimeWindow> {
    @Override
    public void process(Tuple tuple, Context context, Iterable<Integer> iterable, Collector<Tuple2<Long, Integer>> collector) throws Exception {
        context.currentProcessingTime();
        context.window().getStart();
    }
}